package pro.cherish.mqstream.consumer;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * 接收消息通道
 */
public interface OrdersSink {

    String ORDERS_INPUT = "orders_input";

    @Input(OrdersSink.ORDERS_INPUT)
	SubscribableChannel input();

}
